package com.steve.bigdata.flinkmonitor.model;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

import java.io.Serializable;

/**
 * @Author: STEVE
 * @Description: 窗口输出结果
 * @since: 2025-06-26
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@ToString
public class WindowResult implements Serializable {

    private static final long serialVersionUID = 1L;

    /**
     * 分组键（与Event对应）
     */
    private String userId;
    /**
     * 窗口开始时间（毫秒）
     */
    private long windowStart;
    /**
     * 窗口结束时间（毫秒）
     */
    private long windowEnd;
    /**
     * 聚合值：总和
     */
    private double sum;
    /**
     * 聚合值：事件计数
     */
    private long count;

}
